package com.calligraphy.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * 自定义接口
 * @Author hy
 * @Date 2019/1/3 14:57
 **/
@Component
public interface StreamClient {

    String INPUT = "myMsg";

    String OUTPUT = "myMsg1";


    @Input(INPUT)
    SubscribableChannel input();

    @Output(OUTPUT)
    MessageChannel output();

}
